package agent

import "log"

type ZkConfig struct {
	Host string
	Port int
}

type ZkDriver struct {
	config *ZkConfig
}


func (zk *ZkDriver) Conn() error {

	return nil
}

func (zk *ZkDriver) Close() error {
	return nil
}


func (zk *ZkDriver) Read() (int, []byte) {
	log.Println("reading data from zk")
	return 0, nil
}

func (zk *ZkDriver) Output([]byte) error {
	log.Println("writing []byte data to zk")

	return nil
}